package com.briup.day41;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

// 聊天室服务器 - 版本1
// 实现通信的两端能够互发一次信息
public class ChatServer1 {
	
	public static void main(String[] args) {
		
		// 创建并开启服务器
		int port = 8888;
		try {
			ServerSocket ss = new ServerSocket(port);
			System.out.println("服务器已启动，端口号：" + port);
			System.out.println("等待客户端的连接....");
			// 进入侦听状态等待客户端的连接
			Socket socket = ss.accept();
			System.out.println("一台客户端已连接！");
			
			// 接收客户端发来的信息
			InputStream is = socket.getInputStream();
			System.out.println("【客户端说】" + MessageUtil.parseMessage(is));
			
			// 向客户端返回一条信息
			OutputStream os = socket.getOutputStream();
			String msg = MessageUtil.toMessage("Nice to meet you too, Client!");
			os.write(msg.getBytes());
			os.flush();
			
			
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
	
	
	
	
	
}
